5638805fd592bff273287d492cecbc6a70ad67e2,src/main/java/teetime/framework/A3PipeInstantiation.java,A3PipeInstantiation,instantiatePipe,#IPipe#,59
Before Change
Thread sourceStageThread = pipe.getSourcePort().getOwningStage().getOwningThread();
Thread targetStageThread = pipe.getTargetPort().getOwningStage().getOwningThread();
if (targetStageThread == null || sourceStageThread == targetStageThread) { // NOPMD .equals() can't be used here
// normal or reflexive pipe => intra
new UnsynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort());
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Connected (unsynch) " + pipe.getSourcePort() + " and " + pipe.getTargetPort());
}
} else {
// inter
if (pipe.capacity() == 0) {
new UnboundedSynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort());
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Connected (unbounded) " + pipe.getSourcePort() + " and " + pipe.getTargetPort());
}
} else {
new BoundedSynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort(), pipe.capacity());
if (LOGGER.isDebugEnabled()) {
LOGGER.debug("Connected (bounded) " + pipe.getSourcePort() + " and " + pipe.getTargetPort());
}
}
After Change
AbstractStage sourceStage = pipe.getSourcePort().getOwningStage();
AbstractStage targetStage = pipe.getTargetPort().getOwningStage();
if (!targetStage.isActive() || sourceStage == targetStage) { // NOPMD .equals() can't be used here
// normal or reflexive pipe => intra
new UnsynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort());
LOGGER.debug("Connected (unsynch) {} and {}", pipe.getSourcePort(), pipe.getTargetPort());
} else {
// inter
if (pipe.capacity() == 0) {
new UnboundedSynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort());
LOGGER.debug("Connected (unbounded) {} and {}", pipe.getSourcePort(), pipe.getTargetPort());
} else {
new BoundedSynchedPipe<T>(pipe.getSourcePort(), pipe.getTargetPort(), pipe.capacity());
LOGGER.debug("Connected (bounded) {} and {}", pipe.getSourcePort(), pipe.getTargetPort());
}
}
}